package beautiful.butterfly.drds.data_exchange.core.statistics.container.collector;

import beautiful.butterfly.drds.data_exchange.core.statistics.communication.Communication;
import beautiful.butterfly.drds.data_exchange.core.statistics.communication.LocalTGCommunicationManager;

public class ProcessInnerCollector extends AbstractCollector
{

    public ProcessInnerCollector(Long jobId)
    {
        super.setJobId(jobId);
    }

    @Override
    public Communication collectFromTaskGroup()
    {
        return LocalTGCommunicationManager.getJobCommunication();
    }

}
